package com.yonyou.findata.kafka.newapi;


import com.yonyou.findata.kafka.partition.MyPartitioner;
import org.apache.kafka.clients.producer.ProducerConfig;

import java.util.Properties;

/**
 *
 * @author pizhihui
 * @date 2020-06-17
 */
public class ProducerCustomPartitionerDemo {

    public static void main(String[] args) {

        Properties properties = new Properties();
        properties.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, MyPartitioner.class);

    }

}
